package nettyclient.sheng.com.test;

import rx.subjects.PublishSubject;

/**
 * Created by sheng on 2017/5/1.
 */
public class RxEvent<T> {

    private  PublishSubject<T> observable = PublishSubject.create();

    protected RxEvent() {
    }

    public  PublishSubject<T> getObservable() {
        return observable;
    }
    public  void publish(T event) {
        observable.onNext(event);
    }
}
